package com.hw.spark;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import com.hw.spark.service.SparkDemo;
import com.hw.spark.service.SparkStreamService;

@SpringBootApplication
public class SparkApplication {

	public static void main(String[] args) throws InterruptedException {
		
//		SparkDemo sd=new SparkDemo();
//		sd.demo();
//		sd.demo1();
//		sd.demo2();
//		sd.demo3();
		
		SparkStreamService ss=new SparkStreamService();
		ss.sparkStreamTcp();
//		SpringApplication.run(SparkApplication.class, args);
	}

}
